import asyncio

from core.db.deps import database, get_db


async def main():
    await database.connect()
    async for db in get_db():
        print("数据库连接对象：", db)
        print("数据库连接状态：", db.is_connected)
    await database.disconnect()


if __name__ == "__main__":
    asyncio.run(main())
